package com.chukun.disruptor.netty.disruptor.consumer;

import com.chukun.disruptor.netty.disruptor.entity.TranslatorDataWrapper;
import com.lmax.disruptor.WorkHandler;

/**
 * 创建抽象的consumer
 */
public abstract  class MessageConsumer implements WorkHandler<TranslatorDataWrapper> {

    private String consumerID;

    public MessageConsumer(String consumerID) {
        this.consumerID = consumerID;
    }

    public String getConsumerID() {
        return consumerID;
    }

    public void setConsumerID(String consumerID) {
        this.consumerID = consumerID;
    }
}
